const mysql = require("mysql2/promise");

// 创建数据库连接池
const pool = mysql.createPool({
  user: process.env.DB_USER,
  host: process.env.BASE_HOST,
  port: 3306,
  password: process.env.DB_PASSWORD,
  database: "shoesdog",
  multipleStatements: true,
});

// // 封装SQL语句执行方法
// function query(sql) {
//     return new Promise((resolve, reject) => {
//         con.query(sql, (err, data) => {
//             if (err) {
//                 reject(err)
//                 return
//             }
//             resolve(data)
//         })
//     })
// }

// 使用参数化查询
async function query(sql, params = []) {
  try {
    const [rows] = await pool.execute(sql, params);
    return rows;
  } catch (error) {
    console.error("Database query error:", error);
    throw error;
  }
}

module.exports = query;
